package cn.kimming.rpc.remoting.server;

import java.util.concurrent.ThreadFactory;
import java.util.concurrent.atomic.AtomicInteger;

public class MyRpcThreadFactory implements ThreadFactory {

    private AtomicInteger threadId = new AtomicInteger(0);
    @Override
    public Thread newThread(Runnable r) {
        return new Thread(r, "My-Rpc-bussinessPool-" + threadId.getAndIncrement());
    }
}
